package com.biz.primus.ms.geo.stream;

import com.biz.primus.base.constant.GeoStreamConstant;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

/**
 * GeoUpdateSource
 *
 * @author JKLiues
 * @date 2017年11月18日
 */
public interface GeoUpdateSource {
    /**
     * GEO全量信息推送通道
     */
    @Output(GeoStreamConstant.ALL)
    MessageChannel pushAll();

    /**
     * 省更新信息推送通道
     */
    @Output(GeoStreamConstant.PROVINCE)
    MessageChannel pushProvince();

    /**
     * 市更新信息推送通道
     */
    @Output(GeoStreamConstant.CITY)
    MessageChannel pushCity();

    /**
     * 区县更新信息推送通道
     */
    @Output(GeoStreamConstant.DISTRICT)
    MessageChannel pushDistrict();
}